CREATE EXTERNAL TABLE jms_dm.dm_sqs_loss_detail_dt(
  is_filter int COMMENT '是否逻辑删除 1否 , 其他值 是剔除',
  data_source string COMMENT '数据来源：线上理赔/仲裁', 
  loss_type string COMMENT '遗失类型：遗失/疑似遗失', 
  waybill_no string COMMENT '运单号', 
  code string COMMENT '编号', 
  date_time timestamp COMMENT '时间 线上理赔：提交时间，遗失结案时间，疑似 申报时间', 
  submit_status string COMMENT '提交状态1-已提交', 
  is_carrier int COMMENT '是否承运商1:是', 
  source int COMMENT '来源 1-客服', 
  first_duty_network_id string COMMENT '责任网点1id', 
  first_duty_network_code string COMMENT '责任网点1code', 
  first_duty_network_name string COMMENT '责任网点1name', 
  first_duty_proxy_id string COMMENT '责任网点1代理区id', 
  first_duty_proxy_code string COMMENT '责任网点1代理区代码', 
  first_duty_proxy_name string COMMENT '责任网点1代理区名称', 
  first_duty_region_id string COMMENT '责任网点1所属大区id', 
  first_duty_region_code string COMMENT '责任网点1所属大区代码', 
  first_duty_region_name string COMMENT '责任网点1所属大区名称', 
  first_duty_pay_amount decimal(16,4) COMMENT '责任网点1赔付金额', 
  first_duty_network_type int COMMENT '责任网点1网点类型（22-总部 334-代理区335-中心336-一级网点）', 
  first_is_enable tinyint COMMENT '责任网点1网点是否启用', 
  first_is_suspende tinyint COMMENT '责任网点1网点是否暂停', 
  second_duty_network_id string COMMENT '责任网点2网点id', 
  second_duty_network_code string COMMENT '责任网点2网点code', 
  second_duty_network_name string COMMENT '责任网点2网点name', 
  second_duty_proxy_id string COMMENT '责任网点2代理区id', 
  second_duty_proxy_code string COMMENT '责任网点2代理区编码', 
  second_duty_proxy_name string COMMENT '责任网点2代理区名称', 
  second_duty_region_id string COMMENT '责任网点2所属大区id', 
  second_duty_region_code string COMMENT '责任网点2所属大区编码', 
  second_duty_region_name string COMMENT '责任网点2所属大区名称', 
  second_duty_pay_amount decimal(16,4) COMMENT '责任网点2赔付金额', 
  second_duty_network_type int COMMENT '责任网点2网点类型', 
  second_is_enable tinyint COMMENT '责任网点2网点类型 是否启用1启用,2禁用', 
  second_is_suspende tinyint COMMENT '责任网点2网点类型 是否暂停(1是,2否)', 
  third_duty_network_id string COMMENT '责任网点3网点id', 
  third_duty_network_code string COMMENT '责任网点3网点code', 
  third_duty_network_name string COMMENT '责任网点3网点name', 
  third_duty_proxy_id string COMMENT '责任网点3代理区id', 
  third_duty_proxy_code string COMMENT '责任网点3代理区编码', 
  third_duty_proxy_name string COMMENT '责任网点3代理区名称', 
  third_duty_region_id string COMMENT '责任网点3所属大区id', 
  third_duty_region_code string COMMENT '责任网点3所属大区编码', 
  third_duty_region_name string COMMENT '责任网点3所属大区名称', 
  third_duty_pay_amount decimal(16,4) COMMENT '责任网点3赔付金额', 
  third_duty_network_type int COMMENT '责任网点3网点类型', 
  third_is_enable tinyint COMMENT '责任网点3网点是否启用', 
  third_is_suspende tinyint COMMENT '责任网点3网点是否暂停', 
  four_duty_network_id string COMMENT '责任网点4网点id', 
  four_duty_network_code string COMMENT '责任网点4网点code', 
  four_duty_network_name string COMMENT '责任网点4网点name', 
  four_duty_proxy_id string COMMENT '责任网点4代理区id', 
  four_duty_proxy_code string COMMENT '责任网点4代理区编码', 
  four_duty_proxy_name string COMMENT '责任网点4代理区名称', 
  four_duty_region_id string COMMENT '责任网点4所属大区id', 
  four_duty_region_code string COMMENT '责任网点4所属大区编码', 
  four_duty_region_name string COMMENT '责任网点4所属大区名称', 
  four_duty_pay_amount decimal(16,4) COMMENT '责任网点4赔付金额', 
  four_duty_network_type int COMMENT '责任网点5网点类型', 
  four_is_enable tinyint COMMENT '责任网点4网点是否启用', 
  four_is_suspende tinyint COMMENT '责任网点4网点是否暂停', 
  five_duty_network_id string COMMENT '责任网点5网点id', 
  five_duty_network_code string COMMENT '责任网点5网点code', 
  five_duty_network_name string COMMENT '责任网点5网点name', 
  five_duty_proxy_id string COMMENT '责任网点5代理区id', 
  five_duty_proxy_code string COMMENT '责任网点5代理区编码', 
  five_duty_proxy_name string COMMENT '责任网点5代理区名称', 
  five_duty_region_id string COMMENT '责任网点5所属大区id', 
  five_duty_region_code string COMMENT '责任网点5所属大区编码', 
  five_duty_region_name string COMMENT '责任网点5所属大区名称', 
  five_duty_pay_amount decimal(16,4) COMMENT '责任网点5赔付金额', 
  five_duty_network_type int COMMENT '责任网点5网点类型', 
  five_is_enable tinyint COMMENT '责任网点5网点是否启用', 
  five_is_suspende tinyint COMMENT '责任网点5网点是否暂停', 
  network_count int COMMENT '责任网点数', 
  create_network_id string COMMENT '申报网点id', 
  create_network_code string COMMENT '申报网点code', 
  create_network_name string COMMENT '申报网点name', 
  create_parent_id string COMMENT '申报网点代理区id', 
  create_parent_code string COMMENT '申报网点代理区code', 
  create_parent_name string COMMENT '申报网点代理区名称', 
  create_region_id string COMMENT '申报网点大区id', 
  create_region_code string COMMENT '申报网点大区code', 
  create_region_name string COMMENT '申报网点大区name', 
  create_network_type decimal(16,4) COMMENT '申报网点类型', 
  create_is_enable tinyint COMMENT '责任网点3网点 是否启用', 
  create_is_suspende tinyint COMMENT '责任网点3网点 是否暂停', 
  first_type_id string COMMENT '一级异常类型id', 
  first_type_code string COMMENT '一级异常类型code', 
  first_type string COMMENT '一级异常类型名称(冗余)', 
  second_type_id string COMMENT '二级异常类型id', 
  second_type_code string COMMENT '二级异常类型code', 
  second_type string COMMENT '二级异常类型名称(冗余)', 
  create_time timestamp COMMENT '仲裁申报时间', 
  delay_day int COMMENT '延误天数', 
  exception_desc string COMMENT '异常说明', 
  arrival_time timestamp COMMENT '到件时间', 
  collect_time timestamp COMMENT '揽收时间', 
  handling_fee decimal(16,4) COMMENT '手续费需求是handling_fee实际取的是handling_fee_total', 
  is_public_distribution_network int COMMENT '是否共配网点', 
  station_name string COMMENT '门店名称', 
  business_name string COMMENT '品牌名称', 
  pick_network_code string COMMENT '取件网点code', 
  pick_network_name string COMMENT '取件网点name', 
  customer_code string COMMENT '客户code', 
  customer_name string COMMENT '客户name', 
  ordersource_code string COMMENT '订单来源code', 
  ordersource_name string COMMENT '订单来源name', 
  first_virt_code string COMMENT '1责任网点虚拟代理区code,nvl(虚拟代理区,财务中心)', 
  first_virt_name string COMMENT '1责任网点虚拟代理区name,nvl(虚拟代理区,财务中心)', 
  second_virt_code string COMMENT '2责任网点虚拟代理区code,nvl(虚拟代理区,财务中心)', 
  second_virt_name string COMMENT '2责任网点虚拟代理区name,nvl(虚拟代理区,财务中心)', 
  third_virt_code string COMMENT '3责任网点虚拟代理区code,nvl(虚拟代理区,财务中心)', 
  third_virt_name string COMMENT '3责任网点虚拟代理区name,nvl(虚拟代理区,财务中心)', 
  four_virt_code string COMMENT '4责任网点虚拟代理区code,nvl(虚拟代理区,财务中心)', 
  four_virt_name string COMMENT '4责任网点虚拟代理区name,nvl(虚拟代理区,财务中心)', 
  five_virt_code string COMMENT '5责任网点虚拟代理区code,nvl(虚拟代理区,财务中心)', 
  five_virt_name string COMMENT '5责任网点虚拟代理区name,nvl(虚拟代理区,财务中心)')
COMMENT '遗失率明细'
PARTITIONED BY ( dt string COMMENT '时间分区')
stored as parquet
LOCATION '/dw/hive/jms_dm.db/external/dm_sqs_loss_detail_dt'
TBLPROPERTIES ( 'discover.partitions' = 'false',  'parquet.column.index.access' = 'true');

-------中间表
CREATE EXTERNAL TABLE jms_dm.dm_sqs_loss_network_detail_mid_dt(
  date_time timestamp COMMENT '数据时间',
  waybill_no string COMMENT '运单号', 
  loss_type string COMMENT '遗失类型', 
  network_count int COMMENT '责任网点数', 
  network_code string COMMENT '网点编码', 
  network_name string COMMENT '网点name', 
  manage_code string COMMENT '大区code', 
  manage_name string COMMENT '大区name', 
  virt_code string COMMENT '虚拟代理区code', 
  virt_name string COMMENT '虚拟代理区name', 
  financial_center_code string COMMENT '代理区code', 
  financial_center_name string COMMENT '代理区名称', 
  first_type_id string COMMENT '一级异常类型id ',
  first_type_code string COMMENT '一级异常类型code', 
  first_type string COMMENT '一级异常类型', 
  second_type_id string COMMENT '二级异常类型id',
  second_type_code string COMMENT '二级异常类型code', 
  second_type string COMMENT '二级异常类型', 
  data_source string COMMENT '数据来源：线上理赔/仲裁', 
  network_type string COMMENT '网点类型  2-代理区 4-中心 5-集散 6-网点 ')
COMMENT '遗失率明细中间表'
PARTITIONED BY (dt string COMMENT '分区dt')
stored as parquet
LOCATION '/dw/hive/jms_dm.db/external/dm_sqs_loss_detail_dt'
TBLPROPERTIES ( 'discover.partitions' = 'false',  'parquet.column.index.access' = 'true');

alter table jms_dm.dm_sqs_loss_detail_dt
    add columns(
 award_amount_1 decimal(22,2) comment'责任网点1裁定金额'
,handling_fee_1 decimal(22,2) comment'责任网点1手续费'
,award_amount_2 decimal(22,2) comment'责任网点2裁定金额'
,handling_fee_2 decimal(22,2) comment'责任网点2手续费'
,award_amount_3 decimal(22,2) comment'责任网点3裁定金额'
,handling_fee_3 decimal(22,2) comment'责任网点3手续费'
,award_amount_4 decimal(22,2) comment'责任网点4裁定金额'
,handling_fee_4 decimal(22,2) comment'责任网点4手续费'
,award_amount_5 decimal(22,2) comment'责任网点5裁定金额'
,handling_fee_5 decimal(22,2) comment'责任网点5手续费'
,id bigint comment'id'
) cascade;

alter table jms_dim.dm_sqs_loss_network_detail_mid_dt
    add columns (
  amount decimal(22,2) COMMENT '责任网点罚款金额',
  source_type int COMMENT '1线上理赔2仲裁'
) cascade;


alter table jms_dm.dm_sqs_loss_detail_dt
    add columns(
       area_id_1    string comment'网管片区_责任网点id1'
      ,area_code_1  string comment'网管片区_责任网点code1'
      ,area_name_1  string comment'网管片区_责任网点name1'
      ,area_id_2    string comment'网管片区_责任网点id2'
      ,area_code_2  string comment'网管片区_责任网点code2'
      ,area_name_2  string comment'网管片区_责任网点name2'
      ,area_id_3    string comment'网管片区_责任网点id3'
      ,area_code_3  string comment'网管片区_责任网点code3'
      ,area_name_3  string comment'网管片区_责任网点name3'
      ,area_id_4    string comment'网管片区_责任网点id4'
      ,area_code_4  string comment'网管片区_责任网点code4'
      ,area_name_4  string comment'网管片区_责任网点name4'
      ,area_id_5    string comment'网管片区_责任网点id5'
      ,area_code_5  string comment'网管片区_责任网点code5'
      ,area_name_5  string comment'网管片区_责任网点name5'
) cascade;

--alter table jms_dm.dm_sqs_loss_detail_dt
--    add columns(
--      arrival_time timstamp comment'责任网点到件时间'
--) cascade;

alter table jms_dm.dm_sqs_loss_detail_dt change column arrival_time arrival_time timestamp comment '责任网点到件时间';

alter table jms_dm.dm_sqs_loss_detail_dt
add columns(
goods_value decimal(22,2) comment'物品价值'
) cascade;

alter table jms_dm.dm_sqs_loss_network_detail_mid_dt
add columns (
goods_value decimal(22,2) comment'物品价值'
) cascade;

--hive
alter table bidefault.dm_sqs_loss_detail_dt add columns(
     arbitration_award_time         timestamp  comment'仲裁裁定时间'
     ,closing_time                  timestamp  comment'结案时间'
     ,is_package_inner              tinyint  comment'是否是包内件'
     ,award_opinion                 string  comment'仲裁裁定处理意见'
     ,appeal_opinion                string  comment'申诉裁定处理意见'
     ,responsibility_reply_opinion  string  comment'责任方回复信息'
) cascade;
--doris
alter table jms_dm.dm_sqs_loss_detail_dt add column(
     arbitration_award_time         datetime  comment'仲裁裁定时间'
     ,closing_time                  datetime  comment'结案时间'
     ,is_package_inner              tinyint  comment'是否是包内件'
     ,award_opinion                 string  comment'仲裁裁定处理意见'
     ,appeal_opinion                string  comment'申诉裁定处理意见'
     ,responsibility_reply_opinion  string  comment'责任方回复信息'
     ,goods_value  decimal(22,2) comment'物品价值'
     ,award_amount_total   decimal(22,2) comment'合计裁定金额'
) ;